package main

import (
	"lnzw/engine/log"
	"lnzw/engine/nats"

	"go.uber.org/zap"
)

func main() {
	log.Setup()
	nats.Setup()
	nats.SyncQueueSubscribe("test", "test", func(bs []byte) {
		log.Info("test", zap.String("msg", string(bs)))
	})
}
